var express = require('express');
// 引入连接模块
const {query} = require('../db/pool.js')
var router = express.Router();

// 登录接口(post /login)
// 接口地址：/users/login
// 请求方式：POST
router.post('/login', async function(req,res,next){
	// 获取post传递的参数
	var user = req.body
	console.log(user)
	// 判断手机号码和密码是否存在
	if(!user.phone) {
		res.send({
			code: 401,
			msg: 'phone required'
		})
		// 阻止往后执行
		return
	}
	if(!user.upwd) {
		res.send({
			code: 402,
			msg: 'upwd required'
		})
		return
	}
	// 执行SQL命令
	// await等待执行完
	// 还需要在所在的函数前添加async
	// await 必须放入到async内部
	
	
	// 尝试执行，可能出现错误
	try{
		var result = await query('select * from zh_user where phone=? and upwd=?', [user.phone, user.upwd])
	}catch(err){
		// 一旦出现错误会被捕获，不会阻止往后执行
		// 把错误交给错误处理中间件，同时阻止往后执行
		return next(err)
	}
	console.log(result)
	// 如果是空数组说明登录失败，否则登录成功
	if(result.length === 0){
		res.send({code: 400, msg: 'login err'})
	} else {
		res.send({code: 200, msg: 'login suc'})
	}
})

module.exports = router;
